﻿using System.Collections.Generic;
using Yz.Base.Enums;
using Yz.Base.MqModels;

namespace Yz.Mq
{
    public interface IMqFactory<T> where T : MqModel
    {
        MqData<List<T>> CreateMQData(List<T> models, OperateType operateType);
        MqData<T> CreateMQData(T model, OperateType operateType);
        void PublishMQ(MqData<List<T>> datas, string exchangeName);
        void PublishMQ(MqData<T> data, string exchangeName);
    }
}